package me.helllp.book.concurrent.ch05;

import com.lmax.disruptor.WorkHandler;

public class ConsumerDisruptor implements WorkHandler<PCDataDisruptor>{

	@Override
	public void onEvent(PCDataDisruptor arg) throws Exception {
		System.out.println(Thread.currentThread().getId() + " :Event: --" + arg.getValue() * arg.getValue() + "--");
	}

}
